package com.litchi.model;

import lombok.Data;

import java.io.Serializable;
import java.util.Date;
import java.util.Map;

/**
 * @Author: Jiangxx
 * @Date: 2023/10/20
 * @Description:
 */
@Data
public class BaseOperationMessage implements Serializable {

    private static final long serialVersionUID = -4678293442515825150L;

    /**
     * 数据库用户名
     */
    private String owner;

    /**
     * 表名
     */
    private String tableName;

    /**
     * 数据库提交时间(yyyy-mm-dd hh24:mi:ss)
     */
    private String opTime;

    /**
     * 入kafka时间(yyyy-mm-dd hh24:mi:ss)
     */
    private Date loaderTime;

    /**
     * 主键列
     */
    private Map<String, Object> pk;
}
